package com.guqj.mq.kafka;

public interface KafkaConstant {

	// zookeeper 配置
	String ZOOKEEPER_ADDRESS = "127.0.0.1:2181";

	// group 代表一个消费组
	String KAFKA_GROUP_NAME = "kafka_group_1";

	// 序列化
	String KAFKA_SERIALIZER_CLASS = "org.apache.kafka.common.serialization.StringDeserializer";
	
	// kafka topic
	String KAFKA_TOPIC = "kafka_test";
	
	// kafka address
	String KAFKA_ADDRESS = "127.0.0.1:9092";

}
